package com.example.mq.common;

import com.example.mq.mqserver.core.BasicProperties;

import java.io.IOException;

/**
 * 函数式接口（回调函数）
 * 收到消息后处理消息的方法
 */
@FunctionalInterface
public interface Consumer {

    // 每次在服务器收到消息后盗调用
    // 通过这个方法把消息推送给对应的消费者
    void handleDelivery(String consumerTag, BasicProperties basicProperties, byte[] body) throws MqException, IOException;
}
